/* 异步形式的 mysql */

const mysql = require('mysql')

// 创建连接池
const pool = mysql.createPool({
  connectionLimit : 10,
  // host: 'localhost',
  host: '127.0.0.1',
  user: 'root',
  passowrd: '',
  database: 'test',
})


/* 查询 */
function query(sql, values) {
  return new Promise((resolve, reject) => {
    pool.getConnection((err, connection) => {
      if (err) {
        reject(err);
      } else {
        connection.query(sql, values, (err, rows) => {
          /* 查询结果 */
          if (err) {
            reject(err)
          } else {
            resolve(rows)
          }

          connection.release();
        })
      }
    })
  });
}

module.exports = {
  query,
}